package com.feilx.changggou.order.mq;

import com.alibaba.fastjson.JSON;
import com.changgou.mq.MQConstant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
@Slf4j
public class OrderRabbitAcceptMsg {

    //@RabbitListener(queues = {MQConstant.ORDER_QUEUE})
    public void acceptMsg(String msg){
        Map<String,String> map = JSON.parseObject(msg, Map.class);
        log.info("接受到的消息:"+map.toString());
        // 支付状态  return_code
        String return_code = map.get("return_code");
        // 判断是否支付成功
        if(return_code.equals("SUCCESS")){
            // 支付返回结果标识  result_code
            String result_code = map.get("result_code");
            if(result_code.equals("SUCCESS")){

                // 微信支付交易流水号  transaction_id
                String transaction_id = map.get("transaction_id");
                // 商户订单号  out_trade_no
                String out_trade_no = map.get("out_trade_no");
                // 更新订单状态 通知商家发货
            }
        }else{
            // 通知客户支付失败  取消支付
            // 回滚库存
        }






    }
}
